6f5a457fa93ac8b53cc77afd0eb8729f1e5665af,giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java,BspServiceWorker,finishSuperstep,#List#GiraphTimerContext#,873
Before Change
globalCommHandler.finishSuperstep(workerAggregatorRequestProcessor);
MessageStore<I, Writable> incomingMessageStore =
getServerData().getIncomingMessageStore();
if (incomingMessageStore instanceof AsyncMessageStoreWrapper) {
((AsyncMessageStoreWrapper) incomingMessageStore).waitToComplete();
}
After Change
globalCommHandler.finishSuperstep(workerAggregatorRequestProcessor);
MessageStore<I, Writable> incomingMessageStore =
getServerData().getPartitionStore().getIncomingMessageStore();
if (incomingMessageStore instanceof AsyncMessageStoreWrapper) {
((AsyncMessageStoreWrapper) incomingMessageStore).waitToComplete();
}